package org.jadelyre.core.worker;

import org.jadelyre.core.Channel;
import org.jadelyre.core.task.CloseTask;
import org.jadelyre.core.task.EntryQueue;

import java.util.concurrent.ThreadPoolExecutor;

public class CloseWorker extends Worker<Channel> {

    public CloseWorker(ThreadPoolExecutor executor, EntryQueue<Channel> entryQueue) {
        super(executor, entryQueue);
    }

    @Override
    protected void execute() {
        executor.execute(new CloseTask(this));
    }
}
